// server
var es = require('event-stream');
require('net').createServer(function (socket) {
console.log('CONNECTED: ' + socket.remoteAddress +':'+ socket.remotePort);
socket.pipe(es.split())
.pipe(es.map(function (data, cb) {
console.log('Got the following message:', data);
cb(null)
}));
socket.on('end', function () {
console.log("ended: ", socket.remoteAddress, " : ", socket.remotePort);
});
})
.listen(3000);
Была у меня ещё такая реализация но там почему-то добавляется пустой квадрат перед e[{}]